查看原文
其他

使用 Go 语言连接并操作 SQLite 数据库

云原生Go 源自开发者
2024-08-28

在这篇文章中,我们将详细描述如何在 Go 语言中使用 SQLite 数据库。我们将会从如何在 Go 中安装和使用 SQLite 驱动包开始讲起,然后逐步介绍如何创建数据库连接,执行 SQL 查询,处理返回的数据以及关闭数据库连接。

安装 SQLite 驱动

首先,我们需要在 Go 环境里安装 SQLite 的驱动程序,可以使用以下命令进行安装:

go get github.com/mattn/go-sqlite3

创建数据库连接

接下来,使用 sql.Open() 函数,我们可以连接到数据库。期望的两个参数是驱动名称和数据源名称。 比如:

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/mattn/go-sqlite3"
)

func main() {
    db, err := sql.Open("sqlite3""./test.db")
    if err != nil {
        fmt.Println(err)
    }
    defer db.Close()
}

执行 SQL 查询

建立连接之后,我们可以使用 db.Exec() 来执行 SQL 查询。例如,

stmt, err := db.Prepare("CREATE TABLE IF NOT EXISTS userinfo(username TEXT, departname TEXT, created DATE)")
if err != nil {
    log.Fatalln(err)
}
_, err = stmt.Exec()
if err != nil {
    log.Fatalln(err)
}

插入数据

我们可以通过以下方式向表中插入数据:

stmt, err := db.Prepare("INSERT INTO userinfo(username, departname, created) values(?,?,?)")
if err != nil {
    log.Fatalln(err)
}

res, err := stmt.Exec("astaxie""tech""2019-12-09")
if err != nil {
    log.Fatalln(err)
}

id, err := res.LastInsertId()

if err != nil {
    log.Fatalln(err)
}

fmt.Println(id)

查询数据

类似地,我们可以使用 db.Query() 来执行 SQL 查询并获取结果。下面是一个例子:

rows, err := db.Query("SELECT * FROM userinfo")

columns, err := rows.Columns()

values := make([]sql.RawBytes, len(columns))

for i, _ := range values {
    values[i] = new(sql.RawBytes)
}

var value string
for rows.Next() {
    err = rows.Scan(values...)
    if err != nil {
        log.Fatalln(err)
    }

    for _, val := range values {
        if val == nil {
            value = "NULL"
        } else {
            value = string(*val)
        }
    }
    fmt.Println(value)
}

if err = rows.Err(); err != nil {
    log.Fatalln(err)
}

更新数据

更新数据的操作和插入数据类似,都是利用 db.Exec() 来执行 SQL 语句:

stmt, err := db.Prepare("update userinfo set username=? where uid=?")
if err != nil {

updateRes, err := stmt.Exec("astaxieupdate", lastInsertID)
if err != nil {
    log.Fatalln(err)
}

affect, err := updateRes.RowsAffected()

if err != nil {
    log.Fatalln(err)
}
fmt.Println(affect)

删除数据

最后,删除数据操作与插入和更新数据操作类似,同样利用 db.Exec() 来执行 SQL 语句:

stmt, err := db.Prepare("DELETE FROM userinfo WHERE uid=?")
if err != nil {

delRes, err := stmt.Exec(lastInsertID)
if err != nil {
    log.Fatalln(err)
}

affect, err := delRes.RowsAffected()
if err != nil {
    log.Fatalln(err)
}

fmt.Println(affect)

以上就是如何在 Go 语言中操作 SQLite 数据库的基本步骤。


文章精选

Go语言常见错误| 意外的变量隐藏

Go语言常见错误| 不必要的代码嵌套

Go语言常见错误| 误用init函数

Go语言常见错误| 滥用getters/setters

Go语言常见错误 | 接口污染

Go语言常见错误| 将接口定义在实现方一侧


点击关注并扫码添加进交流群领取「Go 语言」学习资料

继续滑动看下一个
源自开发者
向上滑动看下一个

您可能也对以下帖子感兴趣

文章有问题?点此查看未经处理的缓存